package com.msb.strategy.config;

import com.msb.common.constart.RabbitMQConstants;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: lmf
 * @Create: 2025/3/12 20:12
 * @module
 */
@Configuration
public class RabbitMQConfig {
    /**
     * 策略队列
     */
    @Bean
    public Queue mobileQueue() {
        return QueueBuilder.durable(RabbitMQConstants.MOBILE_AREA_SET).build();
    }

    /**
     * 写日志到es队列
     */
    @Bean
    public Queue smsLogEsQueue() {
        return QueueBuilder.durable(RabbitMQConstants.SMS_LOG_ES).build();
    }

    /**
     * 短信发送失败，给客户端推动消息队列
     */
    @Bean
    public Queue smsSendFailQueue() {

        return QueueBuilder.durable(RabbitMQConstants.SMS_SEND_CLIENT).build();
    }

 
}
